package com.cpr.demo.service.mq;

import com.cpr.demo.mycraft.mq.redis.RedisMessage;

/**
 * @author Chen Panrui
 * created at 2021/10/18 17:19
 */
public interface SingleMqReportService {

    /**
     * 保存数据
     * @param queueName 队列名称
     * @param publishMessage 发送消息
     * @param publishNode 发送节点
     */
    void savePublish(String queueName, RedisMessage publishMessage, String publishNode);

    /**
     * 保存数据
     * @param queueName 队列名称
     * @param receiveMessage 接收消息
     * @param receiveNode 接收节点
     */
    void saveReceive(String queueName, RedisMessage receiveMessage, String receiveNode);
}
